package com.xxx;

import io.grpc.stub.StreamObserver;

public class FutureStubTestServiceImpl extends FutureStubTestServiceGrpc.FutureStubTestServiceImplBase {
    @Override
    public void testxxx(FutureStubTestProto.FutureStubTestRequest request, StreamObserver<FutureStubTestProto.FutureStubTestResponse> responseObserver) {
        String name = request.getName();
        System.out.println(name);

        responseObserver.onNext(FutureStubTestProto.FutureStubTestResponse.newBuilder().setResult("futurestubtest response is ok").build());
        responseObserver.onCompleted();
    }
}
